package top.jacktgq.sxt.bio.tcp.demo11;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @Author CandyWall
 * @Date 2019/10/21--14:21
 * @Description 图片上传
 *                 服务器端：
 *                  1、指定端口 使用ServerSocket创建服务器
 *                  2、阻塞式等待连接 accept
 *                  3、操作：输入输出流
 *                  4、释放资源
 */
public class TCPUploadServer {
    public static void main(String[] args) throws IOException {
        //1、指定端口 使用ServerSocket创建服务器
        ServerSocket serverSocket = new ServerSocket(8888);
        //2、阻塞式等待连接 accept
        Socket server = serverSocket.accept();
        System.out.println("一个客户端建立了连接！");
        //3、操作：输入输出流
        InputStream in = new BufferedInputStream(server.getInputStream());
        OutputStream fos = new BufferedOutputStream(new FileOutputStream("upload/2.png"));
        byte[] bytes = new byte[1024];
        int len = -1;
        while ((len = in.read(bytes)) != -1) {
            fos.write(bytes, 0, len);
        }

        /*OutputStream os = server.getOutputStream();
        os.write("上传成功！".getBytes());*/

        //4、释放资源
        fos.close();
        server.close();
        serverSocket.close();
    }
}
